# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dwd.dwd_terminal_sign_all_detail_dt import jms_dwd__dwd_terminal_sign_all_detail_dt
from jms.ods.tab.tab_reback_transfer_express import jms_ods__tab_reback_transfer_express
from jms.dim.dim_sys_network_detail_dt import jms_dim__dim_sys_network_detail_dt
from jms.ods.tab.tab_barscan_sign import jms_ods__tab_barscan_sign
from jms.ods.tab.tab_barscan_collect import jms_ods__tab_barscan_collect


oss__reback_transfer_waybill_detail = BashOperator(
    task_id='oss__reback_transfer_waybill_detail',
    email=['houwenlong@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/reback_transfer_waybill_detail/execute.sh',
    execution_timeout=timedelta(minutes=50),
    sla=timedelta(hours=8)
)

oss__reback_transfer_waybill_detail << [
                                         jms_dwd__dwd_terminal_sign_all_detail_dt,
                                         jms_ods__tab_reback_transfer_express,
                                         jms_dim__dim_sys_network_detail_dt,
                                         jms_ods__tab_barscan_sign,
                                          jms_ods__tab_barscan_collect
                                         ]
